//package cn.maihe.elg.operation.schedule;
//
//import cn.maihe.elg.operation.repository.entity.BidCustomerDO;
//import cn.maihe.elg.operation.repository.entity.OrganizationDO;
//import cn.maihe.elg.operation.repository.mapper.BidCustomerMapper;
//import cn.maihe.elg.operation.repository.mapper.OrganizationMapper;
//import cn.maihe.elg.operation.supports.electronicseal.anne.AnneSignService;
//import cn.maihe.framework.starter.mybatis.dao.MybatisDaoImpl;
//import lombok.extern.slf4j.Slf4j;
//import org.apache.commons.collections.CollectionUtils;
//import org.springframework.scheduling.annotation.Scheduled;
//import org.springframework.stereotype.Component;
//
//import javax.annotation.Resource;
//import java.time.Instant;
//import java.util.Date;
//import java.util.HashMap;
//import java.util.List;
//import java.util.Map;
//
///**
// * @Description
// * @Author WJH
// * @Date 2021/08/10
// */
//
//@Component
//@Slf4j
//public class AnneCreateEnterpriseResultQueryTask {
//
//    @Resource
//    private AnneSignService anneSignService;
//
//    @Scheduled(cron = "${cn.maihe.elg.operation.schedule.createEnterpriseResultCron}")
//    public void resultQuery() {
//
//        try {
//            bidCustomerResultQuery();
//        } catch (Exception e) {
//            log.error("安妮创建投标企业结果查询异常：{}", e.getMessage(), e);
//        }
//
//        try {
//            orgResultQuery();
//        } catch (Exception e) {
//            log.error("安妮创建机构企业结果查询异常：{}", e.getMessage(), e);
//        }
//
//    }
//
//    private void orgResultQuery() {
//        /*更新半小时后记录，且状态未待第三方审核&查询次数小于等于5次的记录，再发起查询*/
//        Map<String, Object> params = new HashMap<>();
//        params.put("curDate", Date.from(Instant.now()));
//
//        List<OrganizationDO> list = MybatisDaoImpl.of(OrganizationMapper.class).selectPageBySql("orgResultQuery", 1, 1000);
//        if (CollectionUtils.isNotEmpty(list)) {
//            list.stream().forEach(o -> {
//                try {
//                    anneSignService.queryEnterprise4org(o.getId());
//                } catch (Exception e) {
//                    log.error("创建机构企业[id:{},creditCode:{}]结果查询异常:{}", o.getId(), o.getCreditCode(), e.getMessage(), e);
//                }
//            });
//        }
//    }
//
//    private void bidCustomerResultQuery() {
//        /*创建半小时后记录，且状态未待第三方审核&查询次数小于等于5次的记录，再发起查询*/
//        Map<String, Object> params = new HashMap<>();
//        params.put("curDate", Date.from(Instant.now()));
//
//        List<BidCustomerDO> list = MybatisDaoImpl.of(BidCustomerMapper.class).selectPageBySql("bidCustomerResultQuery", 1, 1000);
//        if (CollectionUtils.isNotEmpty(list)) {
//            list.stream().forEach(b -> {
//                try {
//                    anneSignService.queryEnterprise4BidCustomer(b.getId());
//                } catch (Exception e) {
//                    log.error("创建投标企业[id:{},creditCode:{}]结果查询异常:{}", b.getId(), b.getBidderCreditCode(), e.getMessage(), e);
//                }
//            });
//        }
//
//    }
//
//
//}
